package com.shujia.util

object TestFlinkTool extends FlinkTool {
  /**
    * 需要在子类实现抽象方法
    *
    */
  override def run(args: Array[String]): Unit = {

    table.executeSql(
      """
        |
        |insert into gma_dim.dim_kafka_mysql_region
        |select a.id,name,area_code,region_name from
        |gma_ods.ods_mysql_kafka_base_province /*+ OPTIONS('scan.startup.mode'='earliest-offset') */ as a
        |left join
        |gma_ods.ods_mysql_kafka_base_region /*+ OPTIONS('scan.startup.mode'='earliest-offset') */ as b
        |on a.region_id=b.id
        |
        |
      """.stripMargin)

  }
}
